package com.icreate.storm.methods.TupleAccumulate;

import org.apache.storm.tuple.ITuple;
import org.bson.Document;

import java.io.Serializable;

/**
 * Created by feng on 2017/5/14.
 */
public interface TupleAccumulator extends Serializable{
    void add(ITuple tuple);

    Document toDocument();

    void reset();
}
